ef58ab284a04818bb32ffb2b28e7253cfbf8519c,gogo/runtime/src/main/java/org/apache/felix/gogo/runtime/Pipe.java,Pipe,setStream,#Channel#number#number#,81
Before Change
mrbc = (MultiReadableByteChannel) streams[fd];
} else {
mrbc = new MultiReadableByteChannel();
mrbc.addChannel((ReadableByteChannel) streams[fd], toclose[fd]);
streams[fd] = mrbc;
toclose[fd] = true;
}
After Change
mrbc = (MultiReadableByteChannel) streams[fd];
} else {
mrbc = new MultiReadableByteChannel();
if (streams[fd] != null && begOfPipe) {
if (toclose[fd]) {
streams[fd].close();
}
} else {
mrbc.addChannel((ReadableByteChannel) streams[fd], toclose[fd]);
}
streams[fd] = mrbc;
toclose[fd] = true;